//package _rxjava2;
//
//import io.reactivex.Observable;
//import io.reactivex.schedulers.Schedulers;
//import org.reactivestreams.Subscriber;
//
///**
// * @author huangya
// * @date 2022/7/8
// */
//public class BackpressureDemo {
//     /** *演示不使用背压 */
//    public void testNoBackpressure () throws InterruptedException {
//        //被观察者（主题）
//        Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
//            @Override
//            public void call(Subscriber<? super String> subscriber) {
//                //循环10次
//                for (int i = 0;i<10 ; i++) {
//                    System.out.println("produce ->" + i);
//                    subscriber.onNext(String.valueOf(i));
//                }
//            }
//        });
//        //观察者
//        Action1<String> subscriber = new Action1<String>() {
//            public void call(String s){ try {
//                //每消费一次间隔50毫秒
//                Thread.sleep(50);
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
//                System.out.println("consumer ->" + s);
//            }
//        };
//        //订阅:observable与subscriber之间依然通过subscribe()进行关联
//        observable .subscribeOn(Schedulers.io()) .observeOn(Schedulers.newThread()) .subscribe(subscriber);
//        Thread.sleep(Integer.MAX_VALUE); }}
